package com.rpcdemo.rpc.transport;

import com.rpcdemo.rpc.ResponseMappingHandler;
import com.rpcdemo.util.PackMsg;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

public class ClientResponse extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        PackMsg packMsg = (PackMsg) msg;

//            System.out.println("client   == " + packMsg);
        ResponseMappingHandler.runCallback(packMsg);

    }
}
